"""6.2 【上下文类】Context 日志回调类服务端开发"""
from time import sleep

from mcp.server.fastmcp import FastMCP,Context
#创建mcp实例

mcp = FastMCP("Context MCP Server")

@mcp.tool()
async def logging_tool(batch_list: list[str],ctx:Context):
    """
    日志回调类服务端开发
    :param batch_list: 批量数据
    :param ctx: 上下文类
    :return: 处理完成
    """
    print("========================日志回调类服务端开发=======================")
    for data in batch_list:
       print(f"[服务端】正在处理数据：{data}")
       await ctx.info(f"正在处理数据：{data}")
       sleep(1)
    return '处理完成'


if __name__ == '__main__':
    mcp.run(transport='sse')
